package com.czk.springboot.reactive.reactor.flux;

import reactor.core.publisher.Flux;

public class FluxLogDemo {

    public static void main(String[] args) {
        
        Flux.range(1, 7)
                // 打印流的日志，上一个流的日志
                .log()
                .filter(i -> i > 3)
                // 上一个流的日志
                .log()
                .map(e -> e + "czk")
                .subscribe(System.out::println);


    }
}
